package com.xbstar.datafusion.store;

import com.alibaba.fastjson.JSONObject;
import com.xbstar.datafusion.controller.RuleDomain;
import com.xbstar.datafusion.util.KafakaServivce;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * Created by jiwenfei on 2018/1/30 16:09 .
 */
@Service
public class StoreService {
    @Autowired
    KafakaServivce kafakaServivce;
    public void originalStore(String data){
        //连kafka，发送topicname=originalstore,值为data
        this.kafakaServivce.send("originalstore",data);
    }
	public void storeByRule(JSONObject jsonp, RuleDomain ruleDomain) {
		// TODO Auto-generated method stub
		
	}
	
}
